package com.ibm.cps.processors;


import java.util.Collection;

import com.ibm.cps.message.ParsedDataMessage;
import com.ibm.cps.sql.expression.function.meta.FieldNameParam;
import com.ibm.cps.sql.expression.function.meta.IgnoredInFunctionCall;
import com.ibm.cps.sql.expression.function.meta.ValueParam;
import com.ibm.interfaces.ITimeSeriesSchema;
import com.ibm.util.exception.CPSException;

public class SampleProcessor extends AbstractProcessor{
	@FieldNameParam
	private String targetField;
	@IgnoredInFunctionCall@ValueParam
	private String outputField;
	@ValueParam
	private double alpha;
	@ValueParam("B")
	private int beta;
	@ValueParam
	private String message;
	
	public SampleProcessor(String tenantId, String processorId) {
		super(tenantId, processorId, "test");
	}

	@Override
	public String toString() {
		return "{\"SampleProcessor\":{\"targetField\":\"" + targetField
				+ "\", \"outputField\":\"" + outputField + "\", \"alpha\":\""
				+ alpha + "\", \"beta\":\"" + beta + "\", \"message\":\""
				+ message + "\"}}";
	}

	@Override
	public void open() throws CPSException {
		
	}



	@Override
	public ITimeSeriesSchema getTimeSeriesSchema() throws CPSException {
		return null;
	}



	@Override
	public Collection<ParsedDataMessage> execute(ParsedDataMessage message)
			throws CPSException {
		return null;
	}



	@Override
	public void dispose() {
		
	}
	
	
}
